package cn.mldn.microcloud.service;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface IStreamClient {

	String INPUT = "myMessageInPut";
	String OUTPUT = "myMessageInPut";
	@Input(INPUT)
	SubscribableChannel input();//消息输入，接收消息
	
	@Output(OUTPUT)
	MessageChannel output();//消息输出，发送消息
}
